package org.lcx.pipeline.example.submitorder;

import org.lcx.pipeline.Processor;
import org.lcx.pipeline.bean.PipelineExeption;
import org.lcx.pipeline.bean.PipelineResult;

import java.util.Map;
import java.util.Random;

/**
 * 公交车
 */
public class StartProcessor implements Processor {

    @Override
    public int runProcess(Object params, PipelineResult result) throws PipelineExeption {
        int resultint = 0;
        StringBuffer msgFormat = new StringBuffer("选择器");

        msgFormat.append("-->开始处理");

        Map paramMap = (Map) params;

        resultint = (int)paramMap.get("start");

        System.out.println(msgFormat.toString());
        return resultint;
    }

}
